const http = require('http');

// 定义请求的选项
const options = {
    hostname: 'localhost',
    port: 3000,
    path: '/stream',
    method: 'GET'
};

// 发起 HTTP 请求
const req = http.request(options, (res) => {
    // 设置响应数据的编码为 UTF-8
    res.setEncoding('utf8');

    // 监听 data 事件，当有新的数据块到达时触发
    res.on('data', (chunk) => {
        // 将数据块输出到终端
        process.stdout.write(chunk);
    });

    // 监听 end 事件，当响应流结束时触发
    res.on('end', () => {
        console.log('\nStream finished.');
    });
});

// 监听请求错误事件
req.on('error', (error) => {
    console.error(`Request error: ${error.message}`);
});

// 结束请求
req.end();